package mq

import "context"

type ConsumeFunc func(ctx context.Context, message []byte) error

type MQ interface {
	Register(callback ConsumeFunc) // 注册回调
	Send(message []byte) error     // 发送消息
	Shutdown()
}
